package com.tianji.aigc.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.tianji.aigc.dto.ChatDTO;
import com.tianji.aigc.entity.ChatSession;
import com.tianji.aigc.vo.ChatEventVO;
import reactor.core.publisher.Flux;

public interface IChatService extends IService<ChatSession> {
    /**
     * 流式对话
     * @param dto
     * @return
     */
    Flux<ChatEventVO> chat(ChatDTO dto);

    /**
     * 停止生成
     * @param sessionId
     */
    void stop(String sessionId);
}
